package com.xiaoze.consumer.sink;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface SinkConsumer {

    String INPUT = "xiaoze";

    String INPUT_SECOND = "xiaoze-second";

    @Input(INPUT)
    SubscribableChannel input();

    @Input(INPUT_SECOND)
    SubscribableChannel inputSecond();
}